//package com.cxy.usercenter.rocketmq;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.cloud.stream.annotation.StreamListener;
//import org.springframework.cloud.stream.messaging.Sink;
//import org.springframework.stereotype.Service;
//
///**
// * @author: huayushu luming
// * @date: 2020-12-01 12:57
// * @desc:
// **/
//@Service
//@Slf4j
//public class MyTestStreamConsumer {
//    @StreamListener(MySink.MY_INPUT)
//    public void receive(String messageBody){
//        log.info("MySink 通过stream收到了消息：messageBody={}",messageBody);
//    }
//}
